package cn.hinglo.activemq.service;

import cn.hinglo.activemq.dao.LogInfoDao;
import cn.hinglo.activemq.entity.LogInfo;
import cn.hinglo.common.constant.QueueConstant;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;


/**
 * @author HingLo
 * @createTime: 2018/9/17 15:55
 * @description: 日志处理消费者
 */
@Component
@Slf4j
public class LogService {

    /**
     * 测试日志记录dao
     */
    private final LogInfoDao logInfoDao;

    @Autowired
    public LogService(LogInfoDao logInfoDao) {
        this.logInfoDao = logInfoDao;
    }

    /***
     * 消息队列测试
     *
     * @param logInfo 日志信息
     */
    @JmsListener(destination = QueueConstant.LOG_QUEUE)
    public void receiveQueue(LogInfo logInfo) {
        logInfoDao.save(logInfo);
        // 需要将日志记录到数据中
        log.info("日志记录成功");
    }
}
